package org.thingsboard.mqtt.broker.session;

import org.thingsboard.mqtt.broker.actors.client.messages.mqtt.MqttPublishMsg;

/**
 * @author fangmingkun
 * @date 2023/8/3 18:40
 * @description
 */
public interface MessageMqttActorManager {
    void processMqttMsg(String clientId, MqttPublishMsg mqttMsg);
}
